//package com.tangcco.websocket;
//
//
//import javax.websocket.*;
//import javax.websocket.server.ServerEndpoint;
//import java.io.IOException;
//import java.util.concurrent.CopyOnWriteArrayList;
//
///**
// * Created by lwx on 2018/2/23.
// */
//@ServerEndpoint("/chat")
//public class ChatServer {
//    Session session;
//    static CopyOnWriteArrayList<ChatServer> servers = new CopyOnWriteArrayList<>();
//    @OnOpen
//    public void onOpen(Session session){
//        this.session = session;
//        servers.add(this);
//        System.out.println("客户端"+session.getId()+"与服务连接成功");
//    }
//
//    //收到消息时执行
//    @OnMessage
//    public void onMessage(String message){
//        System.out.println("开始接受数据："+message);
//        for (ChatServer chatServer : servers) {
//            try {
//                chatServer.session.getBasicRemote().sendText(message);
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
//    }
//
//    @OnClose
//    public void onClose(){
//        System.out.println("与服务器连接已经关闭！");
//        servers.remove(this);
//    }
//
//    @OnError
//    public void onError(Session session,Throwable error){
//        System.out.println("发生错误");
//        error.printStackTrace();
//    }
//}
